package xin.marcher.wind.migrate.constants;

import java.math.BigDecimal;
import java.util.HashMap;

/**
 * 数据常量
 */
public class MigrateConstant {

    /**
     * 滚动批次总数据量缓存 每小时更新一次
     */
    public static HashMap<String, BigDecimal> statisticalCountMap = new HashMap<>();

    /**
     * 拉取消息消费者组
     */
    public static final String MQ_BINLOG_PULL_GROUP = "BINLOG_PULL_GROUP";

    /**
     * 提交消息 offset 消费者组
     */
    public static final String MQ_BINLOG_COMMIT_GROUP = "BINLOG_COMMIT_GROUP";
}
